package com.songjia.stream.test02;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.MessageChannel;

/**
 * 
 * 
 * @Description: 自定义生产者
 *
 * @author: songjia
 * @date: 2018年3月26日 下午2:18:04
 */
public interface SinkSender {

	/**
	 * 自定义一个将名为“input”的消息通道作为输出通道的接口
	 * 
	 * @return
	 */
	@Output(Sink.INPUT)
	MessageChannel output();

	/**
	 * 自定义一个将名为“input2”的消息通道作为输出通道的接口。测试直接注解
	 * 
	 * @return
	 */
	@Output("input2")
	MessageChannel output2();
	
	
	@Output("input3")
	MessageChannel output3();
}
